bd23bcdc5d03267e3e4edee739f5eced0986f3b8,rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/continuations/JMSContinuation.java,JMSContinuation,updateContinuations,#boolean#,154
Before Change
protected void updateContinuations(boolean remove) {
modifyList(remove);
if (jmsConfig.getMaxSuspendedContinuations() < 0
|| jmsListener.getCacheLevel() >= DefaultMessageListenerContainer.CACHE_CONSUMER) {
After Change
// throttle the flow if there're too many continuation instances in memory
synchronized (continuations) {
modifyList(remove);
if (remove && !BOGUS_MESSAGE_SELECTOR.equals(currentMessageSelector)) {
jmsListener.setMessageSelector(currentMessageSelector);
currentMessageSelector = BOGUS_MESSAGE_SELECTOR;